package com.zhongmeng.rxjava2test.base

import io.reactivex.disposables.CompositeDisposable
import io.reactivex.disposables.Disposable

/**
 * author :rcw.
 * date :2017/10/11 10:54.
 */

open class BasePresenter {
    protected var mCompositeDisposable: CompositeDisposable? = null

    //RXjava取消注册，以避免内存泄露
    fun onUnsubscribe() {
        if (mCompositeDisposable != null) {
            mCompositeDisposable!!.dispose()
        }
    }

    //RXjava注册
    fun addSubscription(disposable: Disposable) {
        if (mCompositeDisposable == null) {
            mCompositeDisposable = CompositeDisposable()
        }
        mCompositeDisposable!!.add(disposable)
    }
}
